package com.icesoft.xsnow.mq.consumer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @program: xsnow
 * @description: 消息生产者
 * @author: xuefeng.gao
 * @create: 2019-07-23 12:22
 **/
@SpringBootApplication
@EnableBinding({ XsnowMqConsumerApplication.MySink.class})
public class XsnowMqConsumerApplication {

    public interface MySink {
        @Input("input")
        SubscribableChannel input();

    }


    public static void main(String[] args) {
        SpringApplication.run(XsnowMqConsumerApplication.class, args);
    }


}
